package cloud.xiguapi.ubas.analysis.hotitems.model;

import cloud.xiguapi.ubas.model.UserBehavior;
import org.apache.flink.streaming.api.functions.timestamps.AscendingTimestampExtractor;

/**
 * 用户行为升序时间戳提取器
 *
 * @author 大大大西西瓜皮🍉
 * date: 2021-5-17 上午 09:56
 * desc:
 */
public class UserBehaviorAscendingTimestampExtractor extends AscendingTimestampExtractor<UserBehavior> {

    @Override
    public long extractAscendingTimestamp(UserBehavior element) {
        return element.getTimestamp() * 1000L;
    }
}
